package com.eastfair.messagecenter.service;

import com.eastfair.messagecenter.domain.TaskInfo;

import java.util.List;

/**
 * 消费消息服务
 *
 * @author ligang
 */
public interface ConsumeService {

    /**
     * 从MQ拉到消息进行消费，发送消息
     *
     * @param taskInfoLists
     */
    void consumeSend(List<TaskInfo> taskInfoLists);


//    /**
//     * 从MQ拉到消息进行消费，撤回消息
//     *
//     * @param messageTemplate
//     */
//    void consume2recall(MessageTemplate messageTemplate);


}
